package sicnu.cs.ich.rocketmq.rocketmq;

import org.apache.rocketmq.client.consumer.listener.MessageListener;
import org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently;

/**
 * @author CaiKe
 * @date 2021/12/1 23:11
 */
public interface RocketConsumer {

    /**
     * 初始化消费者
     */
    void init();

    /**
     * 注册监听
     * @param listener
     */
    void registerMessageListener(MessageListenerConcurrently listener);

}
